from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers='192.168.8.5:9092')

producer.send('test-non', b'Hello, World!')

producer.close()